package com.fanxuankai.boot.mqbroker.consumer;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.Set;

/**
 * @author fanxuankai
 */
@Mapper
public interface MsgReceiveMapper extends BaseMapper<MsgReceive> {
    /**
     * 清理
     *
     * @param expire        失效时间 s
     * @param excludeEvents 排除事件
     */
    void clear(@Param("expire") long expire,
               @Param("excludeEvents") Set<String> excludeEvents);
}
